package org.wj.arithmetic

import org.apache.spark.rdd.RDD
import org.apache.spark.{SparkConf, SparkContext}

object Map extends App {


  val conf = new SparkConf().setMaster("local").setAppName(this.getClass.getName)

  val sc = new SparkContext(conf)


  private val rdd: RDD[Int] = sc.parallelize(1 to 10)


  rdd.map(_+1).foreach(println(_))

}
